package com.ynet.eq.haiqing.module.mqtt.impl.datatran;

import com.ynet.eq.haiqing.module.mqtt.MqttMessageStrategy;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.stereotype.Component;

/**
 * @author 胡超雄
 * @date 2021/7/1 16:58
 * @desc 4.2.2 查询单个人员名单详细信息 返回消息的策略处理类
 */
@Component
public class MqttMessageSearchPerson extends MqttMessageStrategy {

    //@Resource
   // private RedisUtil redisUtil;

    @Override
    public void processMessage(String s, MqttMessage message) {

        //TODO 收到了消息 ,放到数据库
        System.out.println("查询人员成功");
        System.out.println(s);
        System.out.println(new String(message.getPayload()));

    }


}
